package com.song.rabbitmq.springbootorderrabbitmqconsumerdirect.service;

import org.springframework.amqp.core.ExchangeTypes;
import org.springframework.amqp.rabbit.annotation.*;
import org.springframework.stereotype.Service;

/**
 * 邮件服务
 */

// bindings其实就是用来确定队列和交换机绑定关系
// email.fanout.queue 是队列名字，这个名字你可以自定随便定义。
// order.fanout 交换机的名字 必须和生产者保持一致

//@RabbitListener(bindings =@QueueBinding(value = @Queue(value = "email.direct.queue",autoDelete = "false"), exchange = @Exchange(value = "direct_order_exchange",type = ExchangeTypes.DIRECT)))
@RabbitListener(queues = {"email.direct.queue"})
@Service
public class EmailService {

    // @RabbitHandler 代表此方法是一个消息接收的方法。该不要有返回值
    @RabbitHandler
    public void messagerevice(String message){
        System.out.println("email 接收到了订单信息是===>" + message);
        // 此处省略发邮件的逻辑
    }

}
